feat: Support search logs by timestamp for structured and unstructured logs. #42
Conversation
# Conflicts: # src/clp_ffi_js/ir/StreamReader.cpp # src/clp_ffi_js/ir/StreamReader.hpp
|
Important Review skippedDraft detected. Please check the settings in the CodeRabbit UI or the You can disable this status message by setting the Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media? 🪧 TipsChatThere are 3 ways to chat with CodeRabbit:
Note: Be mindful of the bot's finite context window. It's strongly recommended to break down tasks such as reading entire modules into smaller chunks. For a focused discussion, use review comments to chat about specific files and their changes, instead of using the PR comments. CodeRabbit Commands (Invoked using PR comments)
Other keywords and placeholders
CodeRabbit Configuration File (
|
There was a problem hiding this comment.
For future commits, you may follow https://github.com/y-scope/clp-ffi-js?tab=readme-ov-file#linting to run the linter
|
|
||
| // Adjust the iterator to find the last valid index | ||
| if (it == m_deserialized_log_events->end() || it->get_timestamp() > input_timestamp) { | ||
| if (it == m_deserialized_log_events->begin()) { |
There was a problem hiding this comment.
Is it possible to check against m_deserialized_log_events->empty() at the beginning of the method and early return, so that we can avoid checking it == m_deserialized_log_events->end() && it == m_deserialized_log_events->begin()?
| if (it == m_deserialized_log_events->begin()) { | ||
| return -1; // No element satisfies the condition | ||
| } | ||
| --it; |
There was a problem hiding this comment.
Can we use std::range::upper_bound instead and always it-- after, so that we can avoid checking (it == m_deserialized_log_events->end() || it->get_timestamp() > input_timestamp)?
| @@ -158,6 +158,29 @@ auto UnstructuredIrStreamReader::decode_range(size_t begin_idx, size_t end_idx, | |||
| ); | |||
| } | |||
|
|
|||
| auto UnstructuredIrStreamReader::find_timestamp_last_occurrence( | |||
There was a problem hiding this comment.
Let's deduplicate this with StructuredIrStreamReader::find_timestamp_last_occurrence.
You may refer to generic_decode_range.
Description
Validation performed